package com.dukk.espark.udf;

import org.apache.spark.sql.api.java.UDF1;



/**
 * 自定义spark  sql function
 * @author shengshi_feiyang@yeah.net
 * @version 2020-09-14
 */
public class DemoUdf implements UDF1<String, Integer> {


    @Override
    public Integer call(String str) throws Exception {
        System.out.println("UDF示例，输入数据"+str);
        return 1;
    }


}
